/**
 * 加载redis
 * @param {*} app
 */
function loadRedis(app) {
  if (app.config.redis) {
    const Redis = require("ioredis");
    if (app.config.redis.cluster && app.config.redis.cluster.length) {
      app.redis = new Redis.Cluster(app.config.redis.cluster);
      app.log.info(
        "redis cluster init seccessfully, usage: this.app.comm.redis",
        true
      );
    } else {
      if (!app.config.redis.port) app.config.redis.port = 6379;
      if (!app.config.redis.host) app.config.redis.host = "127.0.0.1";
      app.redis = new Redis(app.config.redis);
      app.log.info("redis init seccessfully, usage: this.app.redis", true);
    }
  } else {
    app.log.warn("config[redis] undefined, redis uninitialized!", true);
  }
}
module.exports = { loadRedis };
